//package com.ruoyi.common.kafka;
//
//import org.apache.kafka.common.serialization.StringDeserializer;
//import org.apache.kafka.common.serialization.StringSerializer;
//import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
//
///**
// * 此处为了简化，直接将kafka配置信息写到代码中，
// * 实际项目中需要从application.yml配置文件中读取
// *
// * @Author: 倚天照海
// */
//public class MyKafkaConfig {
//    /**
//     * kafka集群地址，多个地址用逗号分隔
//     */
//    private String bootstrapServer = "localhost:9092";
//
//    private String topic = "kjTest";
//
//    /**
//     * 消费者组
//     */
//    private String consumerGroupId = "console-consumer-84014";
//
//    /**
//     * kafka中保存的是将数据序列化后的字节数组，需要指定key和value的序列化方式
//     */
//    private String keySerializerClass = StringSerializer.class.getName();
//
//    private String valueSerializerClass = StringSerializer.class.getName();
//
//    /**
//     * kafka中key和value的反序列化方式
//     */
//    private String keyDeserializerClass = StringDeserializer.class.getName();
//
//    private String valueDeserializerClass = StringDeserializer.class.getName();
//
//    public String getBootstrapServer() {
//        return bootstrapServer;
//    }
//
//    public String getTopic() {
//        return topic;
//    }
//
//    public String getConsumerGroupId() {
//        return consumerGroupId;
//    }
//
//    public String getKeySerializerClass() {
//        return keySerializerClass;
//    }
//
//    public String getValueSerializerClass() {
//        return valueSerializerClass;
//    }
//
//    public String getKeyDeserializerClass() {
//        return keyDeserializerClass;
//    }
//
//    public String getValueDeserializerClass() {
//        return valueDeserializerClass;
//    }
//}
